package com.yin.reactor.service;

import com.yin.reactor.entity.User;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

/**
 * UserService
 *
 * @author Yin Guiqing
 */
public interface UserService {
    /**
     * 根据 id 查询 User
     *
     * @param id 要查询的 id
     * @return 查询的结果
     */
    Mono<User> getUserById(int id);

    /**
     * 查询所有 User
     *
     * @return 查询的结果
     */
    Flux<User> getAllUsers();

    /**
     * 添加 User
     *
     * @param user 要添加的 User
     * @return 。
     */
    Mono<Void> saveUser(Mono<User> user);
}
